#ifndef __MQ_WORKER_HPP__
#define __MQ_WORKER_HPP__

#include "mq_consumer.hpp"
#include "../mqcommon/mq_proto.pb.h"
#include "../mqcommon/mq_log.hpp"
#include "../mqcommon/mq_helper.hpp"
#include "../mqcommon/mq_msg.pb.h"
#include "../mqcommon/mq_threadpool.hpp"

#include "muduo/net/EventLoopThread.h"
#include "../mqcommon/mq_threadpool.hpp"

#include <memory>

namespace mq
{
    class AsyncWorker
    {
    public:
        using Ptr = std::shared_ptr<AsyncWorker>;

        muduo::net::EventLoopThread loopthread;
        threadpool pool;
    };
} 

#endif